package com.nian.message.rocketmq.producer;

import org.apache.rocketmq.client.exception.MQClientException;
import org.apache.rocketmq.client.producer.SendResult;
import org.apache.rocketmq.client.producer.TransactionSendResult;

/**
 * 用途：
 * 开发：zhangmj
 * 日期：2020/4/6 20:50
 */
public interface IRocketMQProducer {

    public static final String TOPIC_NAME = "message_topic_test_2020_04";

    SendResult send(String topic, String tag, String body);

    TransactionSendResult sendMessageInTransaction(String topic, String tag, String body) throws MQClientException;
}
